from emr.emr_cluster import EmrCluster, EmrClusterProvision
from choreography.jobs_manager import get_next_job

event = {
        "detailType": "Spider State-change Notification",
        "source": "pt.spider",
        "detail": {"state": "COMPLETED", "name": "BestSeller"}
    }

next_job = get_next_job(event)["jobType"]

provision = EmrClusterProvision()
emrCluster = EmrCluster(provision)
response = emrCluster.submit_job()
print("done")
